package com.sunday.common.mq.kafka.study.spring.e21_Brave_Trace_Pull;

import com.sunday.common.mq.kafka.brave.annotation.TracingKafkaHandler;
import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.stereotype.Controller;

@Slf4j
@Controller
public class MQController {

    @TracingKafkaHandler
    public void receive(ConsumerRecord<Object, Object> consumerRecord) {
        log.info("========= {}", consumerRecord);
    }

    @TracingKafkaHandler
    public void receive() {
        log.info("========= {}");
    }

}
